package com.springboot.study.config;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/*
* 说明：
* @Configuration：表示这是一个 Spring 配置类。
* WORK_QUEUE：定义队列名称。
* QueueBuilder.durable()：创建一个持久化队列，RabbitMQ 重启后消息不会丢失。
* */
@Configuration
public class WorkQueueConfig {
    public static final String WORK_QUEUE = "work.queue";// 定义队列名称
    @Bean
    public Queue workQueue() {// 创建队列
        return QueueBuilder.durable(WORK_QUEUE).build();// 创建持久化队列
    }
}